import utils.Kafka;

public class Run {
    public static void main(String[] args) {
        Kafka.createTopic("192.168.88.131:9092","ETC_flink");
    }
}
